package com.fafu.mq.common;

import com.fafu.mq.mqserver.core.BasicProperties;

import java.io.IOException;

/**
 * 只是一个单纯的函数时接口
 */


@FunctionalInterface
public interface Consumer {
    // Delivery 的意思是 "投递", 这个方法希望每次服务器收到消息之后, 再来调用
    // 通过这个方法把消息推给消费者
    // 这里的方法名都是参考 RabbitMQ 的
    void handleDelivery(String consumerTag, BasicProperties basicProperties, byte[] body) throws MqException, IOException;
}
